package com.chukun.flink.stream.window.time;

import com.chukun.flink.stream.window.process.bean.EventBean;
import org.apache.flink.api.common.eventtime.TimestampAssigner;

/**
 * @author chukun
 * @version 1.0.0
 * @description 抽取事件时间
 * @createTime 2022年05月24日 23:49:00
 */
public class EventTimestampExtractor implements TimestampAssigner<EventBean> {
    @Override
    public long extractTimestamp(EventBean eventBean, long timestamp) {
        return eventBean.getTime();
    }
}
